package com.gi.product.message;

import com.gi.product.dto.CartDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

/**
 * Created by lancf on 2019/7/11.
 */
@Component
@Slf4j
@EnableBinding(StreamClient.class)
public class StreamMessageRecive {


//    @StreamListener(value=StreamClient.OUTMSG)
//    public void stream1(Object msg) {
//        log.info("stream 监听到的消息{}", msg);
//    }
//
//
//    @StreamListener(value=StreamClient.OUTMSG)
//    public void stream1(CartDTO cartDTO) {
//        log.info("stream 监听到的消息{}", cartDTO.toString());
//    }

}
